from sqlalchemy import create_engine
from sqlalchemy.orm import sessionmaker
from model import User

# 1. 链接数据库等准备工作
engine = create_engine('mysql+pymysql://root:python@localhost:3306/19python')
DBSession = sessionmaker(bind=engine)
session = DBSession()

# 2. 删除数据

# 方式1
# 删除id=2的数据
user = session.query(User).filter(User.id == 2).one()
session.delete(user)

# 方式2
# 删除id>=2的数据 删除多个
del_num = session.query(User).filter(User.id >= 2).delete()
print(del_num)

# 3. 提交（只要是增删改任意一种都意味着对数据进行了修改，都需要commit）
session.commit()

# 4. 关闭session
session.close()
